package com.duobaoyu.dby.supply.db.repository.message;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.duobaoyu.dby.supply.db.entity.message.MqMessage;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;

import java.util.List;

/**
 * @author liyang
 * @version 1.0.0
 * @ClassName MqMessageService
 * @Description RocketMq生产者消息
 * @createTime 11:23:00 2023/10/07
 */
public interface MqMessageRepository /*extends DbyService<MqMessage>*/ {

    boolean save(MqMessage mqMessage);

    boolean update(Query query, Update update);

    Page<MqMessage> page(Page<MqMessage> page,Query query);

    MqMessage selectById(String mqMessageId);

    List<MqMessage> mqMessageList(Query query);
}
